/*    */ package eos.moe.dragoncore;
/*    */ 
/*    */ import java.io.IOException;
/*    */ import java.io.InputStream;
/*    */ 
/*    */ public class pe
/*    */   extends InputStream
/*    */ {
/*    */   private static final int z = 15;
/*    */   private InputStream i;
/* 11 */   private long w = 0L;
/* 12 */   private byte[] q = new byte[1];
/*    */   private long g;
/*    */   
/*    */   public pe(InputStream inputStream, long l) {
/* 16 */     this.i = inputStream;
/* 17 */     this.g = l;
/*    */   }
/*    */ 
/*    */   
/*    */   public int read() throws IOException {
/* 22 */     int i = read(this.q);
/* 23 */     if (i == -1) {
/* 24 */       return -1;
/*    */     }
/*    */     
/* 27 */     return this.q[0];
/*    */   }
/*    */ 
/*    */   
/*    */   public int read(byte[] arrayOfByte) throws IOException {
/* 32 */     return read(arrayOfByte, 0, arrayOfByte.length);
/*    */   }
/*    */ 
/*    */ 
/*    */   
/*    */   public int read(byte[] arrayOfByte, int i, int j) throws IOException {
/* 38 */     if (this.g != -1L) {
/* 39 */       if (this.w >= this.g) {
/* 40 */         return -1;
/*    */       }
/*    */       
/* 43 */       if (j > this.g - this.w) {
/* 44 */         j = (int)(this.g - this.w);
/*    */       }
/*    */     } 
/*    */     
/* 48 */     int k = this.i.read(arrayOfByte, i, j);
/*    */     
/* 50 */     if (k > 0) {
/* 51 */       this.w += k;
/*    */     }
/*    */     
/* 54 */     return k;
/*    */   }
/*    */ 
/*    */   
/*    */   public int v(byte[] arrayOfByte) throws IOException {
/* 59 */     int i = this.i.read(arrayOfByte);
/*    */     
/* 61 */     if (i != arrayOfByte.length) {
/* 62 */       i = v(arrayOfByte, i);
/*    */       
/* 64 */       if (i != arrayOfByte.length) {
/* 65 */         throw new IOException("Cannot read fully into byte buffer");
/*    */       }
/*    */     } 
/*    */     
/* 69 */     return i;
/*    */   }
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */ 
/*    */   
/*    */   public void close() throws IOException {
/* 93 */     this.i.close();
/*    */   }
/*    */   
/*    */   public long v() {
/* 97 */     return this.w;
/*    */   }
/*    */ }


/* Location:              D:\fanbian\[D][龙之核心]DragonCore-2.6.0.3.jar!\eos\moe\dragoncore\pe.class
 * Java compiler version: 8 (52.0)
 * JD-Core Version:       1.1.3
 */